package com.navinfo.tripanalysis.service;


import com.navinfo.tripanalysis.pojo.LoadDataParam;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.sql.SparkSession;

import java.io.Serializable;

public interface LoadAbnormalTripStatictisDataService extends Serializable {

    void insert (SparkSession spark, JavaSparkContext jsc , LoadDataParam param);
}
